package com.wenjoying.user.message;

import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.messaging.Message;

@EnableBinding(MySink.class)
public class Customer {

//    @StreamListener(MySink.INPUT)
//    public void received(Message msg) {
//
//        System.out.println(msg.getPayload());
//    }

}
